package cn.me.alphamq.broker.rebalance.strategy;

/**
 * 重平衡策略的接口
 *
 * @author f
 */
public interface RebalanceStrategy {

    /**
     * 重平衡指定主题下指定消费者组的队列
     *
     * @param topic         指定的主题
     * @param consumerGroup 指定的消费者组
     */
    void rebalance(String topic, String consumerGroup);

}
